Crate fluvio_socket

source ·

Structs

  • Implement async socket where response are send back async manner they are queued using channel
  • Low level configuration option to directly connect to Fluvio This can bypass higher level validation required for CLI and end user application
  • Multi-thread aware Sink. Only allow sending request one a time.
  • Socket abstract that can send and receive fluvio objects
  • inner flv stream which is generic over stream
  • Socket that can multiplex connections
  • Connection that perform request/response
  • This sockets knows about support versions Version information are automatically insert into request
  • wrap around versions

Enums

Traits

Functions

  • send request and return response from calling server at socket addr

Type Aliases